package com.flute.haflute.jobbox.child;

import com.flute.haflute.jobbox.common.TransferredFileWriter;
import com.flute.haflute.jobbox.communication.messages.FileTransferMessage;
import com.flute.haflute.jobbox.communication.messages.MessageBase;

/**
 * 传输文件中进行文件读写的任务，在从节点运行<br>
 */
public class FileTransferTask implements TaskScheduler {

	@Override
	public void scheduleTask(MessageBase request) throws Exception {
		TransferredFileWriter fileWriter = new TransferredFileWriter();
		fileWriter.writeContentFromMessage((FileTransferMessage) request);
	}
}
